51a451300a1af7cf7bc01e53befb03bbcbc89e82,spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java,KafkaBinderTests,testAutoAddPartitionsDisabledSucceedsIfTopicPartitionedCorrectly,#,557

Before Change


		String testTopicName = "existing"  + System.currentTimeMillis();
		AdminUtils.createTopic(kafkaTestSupport.getZkClient(), testTopicName, 6, 1, new Properties());

		KafkaMessageChannelBinder binder = new KafkaMessageChannelBinder(
				new ZookeeperConnect(kafkaTestSupport.getZkConnectString()), kafkaTestSupport.getBrokerAddress(),
				kafkaTestSupport.getZkConnectString());
		GenericApplicationContext context = new GenericApplicationContext();
		binder.setAutoAddPartitions(false);
		RetryTemplate metatadataRetrievalRetryOperations = new RetryTemplate();
		metatadataRetrievalRetryOperations.setRetryPolicy(new SimpleRetryPolicy());
		FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();

After Change



		String testTopicName = "existing"  + System.currentTimeMillis();
		AdminUtils.createTopic(kafkaTestSupport.getZkClient(), testTopicName, 6, 1, new Properties());
		KafkaBinderConfigurationProperties configurationProperties = createConfigurationProperties();
		configurationProperties.setAutoAddPartitions(false);
		KafkaMessageChannelBinder binder = new KafkaMessageChannelBinder(configurationProperties);
		GenericApplicationContext context = new GenericApplicationContext();
		RetryTemplate metatadataRetrievalRetryOperations = new RetryTemplate();
		metatadataRetrievalRetryOperations.setRetryPolicy(new SimpleRetryPolicy());